/*
 * @Description: 
 * @Author: changqing
 * @Date: 2021-08-30 20:04:52
 * @LastEditTime: 2021-08-30 20:05:54
 * @LastEditors: changqing
 * @Usage: 
 */
var { of} = require('rxjs'); 
var {filter} = require('rxjs/operators');

const filterPassScore = () => {
  return (source$) => {
    return source$.pipe(
      filter((score) => score >= 60)
    );
  };
};
const scores = of( 80,36, 49, 100);
scores.pipe(filterPassScore()).subscribe(console.log);
// 80 100